from multiprocessing import Queue

# q = Queue(3)  # 可以设置元素个数
#
# def func():
#     print('in func')
#
# q.put('alex')
# q.put({'count': 1})
# q.put(func)
# print(222)
# q.put(666)  # 当队列数据已经达到上限,在插入数据的时候,程序就会夯住.
# print(111)

# print(q.get())
# print(q.get())
# print(q.get())
# ret = q.get()
# ret()

# 当你将数据取完继续在取值时,
# print(q.get())
# print(q.get())
# print(q.get())
# print(q.get())

# 1. maxsize()   q = Queue(3)  数据量不易过大.精简的重要的数据.
# 2. put block 默认为True 当你插入的数据超过最大限度,默认阻塞.
# q = Queue(3)  # 可以设置元素个数
#
# q.put('alex')
# q.put({'count': 1})
# q.put(22)  #
# q.put(333,block=False)  # 改成False 数据超过最大限度,不阻塞了直接报错.
# 3. put timeout() 参数
# q = Queue(3)  # 可以设置元素个数
#
# q.put('alex')
# q.put({'count': 1})
# q.put(22)  #
# q.put(333,timeout=3)  # 延时报错,超过三秒再put不进数据,就会报错.

# q = Queue()
# q.put('alex')
# q.put({'count': 1})
# q.put(22)  #
#
# print(q.get())
# print(q.get())
# print(q.get())
# print(q.get(block=False))  timeout
